package wang.chunfan.springcloud.learning.stream.rabbitmq.server;

import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;
import wang.chunfan.springcloud.learning.stream.rabbitmq.processor.RabbitProcessor;

@Component
public class Consumer {

    @StreamListener(RabbitProcessor.INPUT_TEST)
    public void receive(String message) {
        System.out.println("获得消息：" + message);
    }
}
